package com.zc.analysis.support;

import com.ruoyi.common.utils.spring.SpringUtils;
//import  com.zc.component.network.custom.CustomDeviceGatewayProvider;
import com.zc.core.message.DeviceMessage;
import reactor.core.publisher.Flux;

public class PlatformDeviceDataAccessSupport {

//    private static CustomDeviceGatewayProvider provider;
//
//
//    public static void handlerClientDeviceMessage(Flux<? extends DeviceMessage> flux){
//        if(provider == null){
//            init();
//        }
//        flux.flatMap(m->provider.handleDeviceMessage(m.getDeviceId(), m)).then().block();
//    }
//
//    private static void init() {
//        provider = SpringUtils.getBean("customDeviceGatewayProvider");
//    }
}
